from celery_app import app
from datetime import datetime

@app.task
def print_time():
    print(f"Current time: {datetime.now()}")

# 加载定时任务配置
from celerybeat_schedule import beat_schedule
app.conf.beat_schedule = beat_schedule 